package com.zxy.zxyrpc.utils;

import io.lettuce.core.cluster.pubsub.RedisClusterPubSubAdapter;

/**
 * redis 监听类
 *
 * @author zxy
 * @since 2025/6/2
 **/
public class ClusterSubscriber extends RedisClusterPubSubAdapter<String, String> {
    public void message(String channel, String message) {
        // 在这里处理过期事件，例如根据 key 执行业务逻辑
    }
}
